package com.atguigu.kafka.flink;

import com.atguigu.kafka.flink.model.Person;
import org.apache.flink.api.java.functions.KeySelector;

public class PersonKeySelector implements KeySelector<Person, String> {
    @Override
    public String getKey(Person person) throws Exception {
        return person.getName();
    }
}
